package com.kacheap.config.jms;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * 消息Consumer
 * 
 * @author ray
 *
 */
@Component
public class JmsConsumer {
	public static final String QUEUE_NAME = "mytest.queue";

	@JmsListener(destination = QUEUE_NAME)
	public void receiveQueue(String text) {
		System.err.println("收到MQ消息 ==> " + text);
	}

}
